const redis = require('redis');

// Redis连接配置
const redisConfig = {
    host: process.env.REDIS_HOST || 'localhost',
    port: process.env.REDIS_PORT || 6379,
    database: process.env.REDIS_DB || 1
};

// 创建Redis客户端
const redisClient = redis.createClient(redisConfig);
redisClient.connect();
// 错误处理
redisClient.on('error', (err) => {
    console.error('Redis连接错误:', err);
});

// 连接成功处理
redisClient.on('connect', () => {
    console.log('Redis连接成功');
});

// 确保在应用关闭时正确关闭Redis连接
process.on('SIGINT', () => {
    redisClient.quit();
    process.exit();
});

module.exports = redisClient; 